package com.song.shop.rocketmq;

import org.apache.rocketmq.common.message.MessageExt;
import org.springframework.stereotype.Component;

/**
 * @author Song Yinghui
 * @date 2018/12/18
 * @Version 1.0
 */
@Component
public class TestCustomer2 implements ICustomerCallBack {
    @Override
    public String getTopic() {
        return "broker-a";
    }

    @Override
    public void process(MessageExt msg) {
        System.out.println("TestCustomer2 正在处理消息"+new String(msg.getBody()));
    }
}
